package com.dxf.bigdata.D05_spark_again

import org.apache.spark.rdd.RDD
import org.apache.spark.{SparkConf, SparkContext}

import java.util.{Calendar, Date}

object Sample {

  def main(args: Array[String]): Unit = {

    val sparkConf = new SparkConf().setMaster("local[*]").setAppName("app")

    val sc = new SparkContext(sparkConf)


    val rdd: RDD[Int] = sc.makeRDD(List(1, 2, 3, 4, 5, 6, 7, 8, 9, 10))

    rdd.sample(
      false,// 伯努利算法  去除后,是否放回,true 放回
      0.4, //每天记录抽取概论
      2 //算法种子,种子不变得到结果一样,默认当前系统时间
    ).collect().foreach(println)


    println(rdd.sample(
      true, //泊松算法
      3,// 每条数据被抽取次数, 1-10 概论3次
//      1
    ).collect().mkString(","))



    //别忘记
    sc.stop()




  }
}